<?php
/**
 * 队列消费测试
 * @author yupoxiong<i@yupoxiong.com>
 */

declare (strict_types=1);

namespace app\queue\redis;

use support\Log;
use Webman\RedisQueue\Consumer;

class ExportExcelConsumer implements Consumer
{
    // 要消费的队列名
    public string $queue = 'export_excel';

    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public string $connection = 'default';

    // 消费
    public function consume($data)
    {
        Log::info('队列消费', $data);
    }
}